Day 20 我們說明了分散式運算引擎對即時進行資料應用的優勢之處。以 RFM 分析而言,我們把資料源的變化捕捉到 Kafka 之後,就可以接上 Flink 作...
今天我們透過 python 來實作 RabbitMQ 安裝 Linux sudo apt-get install rabbitmq-server sudo s...
之前一直有想學其他的 Message Queue,趁這次機會和大家一起來好好瞭解 RabbitMQ What is RabbitMQ RabbitMQ 是一個開...
「資料變化要能即時反映出來,並透過事件的形式進行串接。」基於這樣的概念,我們需要在異動資料抵達系統時,在毫秒或秒級就處理完成。今天就逐步拆解概念,一一掌握技術...
根據維基百科對於訊息佇列的說明:是一種行程間通訊或同一行程的不同執行緒間的通訊方式,軟體的貯列用來處理一系列的輸入,通常是來自使用者。訊息佇列提供了非同步的通訊...
雖然 Message Queue 沒有一個標準化規範, 實作會根據業務情境有些許不同, 但大多數都支援以下功能 生產者-消費者 模式 (Producer-Co...
我們已經擴展了外部和內部的 API Service, 透過均衡負載器分散流量給每一個伺服器, 可以說我們透過均衡負載器將 外部服務 和 內部服務 "解...
[Day31] Message Queue 初探(1) : 以 Redis 作為 Message Queue 執行 Speech Recognition 本次...
哈囉大家好,我是古古 到上一篇文章為止,我們已經了解了 Google Cloud 中的 API 管理服務,那麼接著這篇文章,就會進入到第五部分,也就是介紹 Go...
昨天的文章,向讀者介紹了 MQ 架構中的「交換機」(exchange)概念,並練習了 Fanout 與 Direct 模式。而本文將會實作「Routing」與「...
昨天的文章實作了簡單的 Simple 與 Worker 模式。而接下來將加入「交換機」(exchange)這項元素,讓 producer 在發送訊息到多個 qu...
昨天的進度是安裝 RabbitMQ,並準備 Spring Boot 專案與之連接。而本文會以最小的規模實作「傳送資料到 MQ」與「從 MQ 拿取資料做處理」的過...
在分散式架構的系統中,會有多個應用程式在運行各自的服務。而程式間會有傳遞資料的行為,也就是「通訊」。訊息佇列讓我們在請另一方的服務處理任務時,能以非同步的方式進...
[深入淺出MQTT]: v3.1.1與v5 的差異 MQTT v3.1.1 與 v5 完全相容,且提供許多Cluster 所需要的功能,如Shared Subs...
針對一些可能遇到的問題或需求,跟大家分享一下須注意的地方或處裡的方式。 Config Options MaxAttempts : NSQ consumer 嘗...
昨天簡單介紹過 NSQ架構與組成要件,今天我們來看一下實際使用的方式,與使用時需要注意的地方。範例會延續昨天架在 kubernetes 的 NSQ,請還沒有安裝...
在進行分散式運算時如果是想發送至不同實體, 我們可直接發出請求並等待回傳結果,但這樣在等待回傳時的運算能力是被閒置的,故此聰明的我們可能會用 goroutine...
這是 message queue 系列文第三篇,以下附上前兩篇連結 讓任務排隊吧:Message Queue — (1)讓任務排隊吧:Message Queue...
上回介紹了 message queue 的基本觀念與使用時機(想複習觀念的可以看上一篇),今天則要介紹業界常用的第三方 message queue 服務 —...
上個觀念 IOC 強調程式碼的品質,第二個觀念 message queue 強調的則是 “訊息的溝通”。 接下來會利用三篇文章的篇幅講解 message que...